package com.xbongbong.pro.rabbitmq.binders;

import com.xbongbong.pro.rabbitmq.constant.DistributorBinderConstant;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Service;

/**
 * crm 消息队列
 * @author 魏荣杰
 * @date 2019/2/22 18:48
 * @since v1.0
 * @version v1.0
 */
@Service("distributorCustomerBinder")
public interface DistributorConsumerBinder {
    /**
     * 经销商
     */
    @Input(DistributorBinderConstant.DISTRIBUTOR_INPUT)
    SubscribableChannel distributorInput();
    //    @Output(CrmBinderConstant.CONTACT_OUTPUT)
    //    MessageChannel contactOutput();
    /**
     * 经销商 移交
     */
    @Input(DistributorBinderConstant.DISTRIBUTOR_HANDOVER_INPUT)
    SubscribableChannel distributorHandoverInput();
    //    @Output(CrmBinderConstant.CONTACT_OUTPUT)
    //    MessageChannel contactOutput();
    /**
     * 经销商联系人
     */
    @Input(DistributorBinderConstant.DISTRIBUTOR_CONTACT_INPUT)
    SubscribableChannel distributorContactInput();

    /**
     * 跟进记录
     */
    @Input(DistributorBinderConstant.DISTRIBUTOR_COMMUNICATE_INPUT)
    SubscribableChannel distributorCommunicateInput();

}
